Skip to content
This repository has been archived by the owner on Sep 1, 2020. It is now read-only.

Latest commit

 

History

History
58 lines (44 loc) · 2.85 KB

6.2.1 - swoole_event_add.md

File metadata and controls

58 lines (44 loc) · 2.85 KB

swoole_event_add

swoole_event_add函数用于将一个socket加入到底层的reactor事件监听中。此函数可以用在ServerClient模式下。 函数原型:

bool swoole_event_add(mixed $sock, mixed $read_callback, mixed $write_callback = null,
	int $flags = null);

参数

参数1可以为以下四种类型:

  • int,就是文件描述符,包括swoole_client->$sockswoole_process->$pipe或者其他fd
  • stream资源,就是stream_socket_client/fsockopen创建的资源
  • sockets资源,就是sockets扩展中socket_create创建的资源,需要在编译时加入 ./configure --enable-sockets
  • objectswoole_processswoole_client,底层自动转换为管道或客户端连接的socket

参数2为可读回调函数,参数3为可写事件回调,可以是字符串函数名、对象+方法、类静态方法或匿名函数,当此socket可读时回调指定的函数。

参数4为事件类型的掩码,可选择关闭/开启可读可写事件,如SWOOLE_EVENT_READSWOOLE_EVENT_WRITE,或者SWOOLE_EVENT_READ | SWOOLE_EVENT_WRITE

在 Server 程序中使用时,必须在 Worker 进程启动后使用。在 Server::start 之前不得调用任何异步 IO 接口

返回值

  • 添加事件监听成功成功返回true
  • 添加失败返回false,请使用swoole_last_error获取错误码
  • 已添加过的socket不能重复添加,可以使用swoole_event_set修改socket对应的回调函数和事件类型

使用swoole_event_addsocket加入到事件监听后,底层会自动将该socket设置为非阻塞模式

使用实例

$fp = stream_socket_client("tcp://www.qq.com:80", $errno, $errstr, 30);
fwrite($fp,"GET / HTTP/1.1\r\nHost: www.qq.com\r\n\r\n");

swoole_event_add($fp, function($fp) {
	$resp = fread($fp, 8192);
 	//socket处理完成后,从epoll事件中移除socket
	swoole_event_del($fp);
	fclose($fp);
});
echo "Finish\n";  //swoole_event_add不会阻塞进程,这行代码会顺序执行

回调函数

  • 在可读事件回调函数中必须使用freadrecv等函数读取socket缓存区中的数据,否则事件会持续触发,如果不希望继续读取必须使用Swoole\Event::del移除事件监听
  • 在可写事件回调函数中,写入socket之后必须调用Swoole\Event::del移除事件监听,否则可写事件会持续触发
  • 执行freadsocekt_recvsocket_readSwoole\Client::recv返回false,并且错误码为EAGAIN时表示当前socket接收缓存区内没有任何数据,这时需要加入可读监听等待EventLoop通知
  • 执行fwritesocket_writesocket_sendSwoole\Client::send操作返回false,并且错误码为EAGAIN时表示当前socket发送缓存区已满,暂时不能发送数据。需要监听可写事件等待EventLoop通知